const express = require("express");
const app = express();
const http = require("http");
const server = http.createServer(app);
const MySocketIOServer = require("./socketIO/index");
MySocketIOServer.init(server);

const port = 3000; //监听端口

// 解决跨域问题
app.all("*", function (req, res, next) {
	// 设置允许跨域的域名,*代表允许任意域名跨域
	res.header("Access-Control-Allow-Origin", "*");
	// 允许的header类型
	res.header("Access-Control-Allow-Headers", "content-type");
	// 跨域允许的请求方式
	res.header("Access-Control-Allow-Methods", "DELETE,PUT,POST,GET,OPTIONS");
	if (req.method.toLowerCase() == "options") res.send(200); // 让options 尝试请求快速结束
	else next();
});

app.use(express.json());

app.post("/sendMsg", function (req, res) {
	const { toUser, data } = req.body;
  if(!data){
    res.send("缺少参数data,或者data不能为kong");
    return;
  }
  if(toUser===''||toUser){
    MySocketIOServer.sendToSomeBody(toUser, data);
		res.send("ok");
  }
});

server.listen(port, () => {
	console.log("服务启动监听端口:" + port);
});
